﻿using MassTransit;
using System.Threading.Tasks;

namespace MessageBus.Consumer
{
    public class MessageConsumer<T> : IConsumer<T> where T : class
    {
        public string Group { get; set; }
        public string Topic { get; set; }


        public async Task Consume(ConsumeContext<T> context)
        {
            await context.Publish(context.Message);
        }
    }
}